package com.dong.common.mq;

import com.aliyun.openservices.ons.api.MessageListener;
import com.aliyun.openservices.ons.api.bean.ConsumerBean;
import com.aliyun.openservices.ons.api.bean.ProducerBean;

/**
 * @author zhaodongchao
 * @date 2020/11/19 14:38
 */
public interface MqService {

    /**
     * 根据配置来创建一个消息的生产者实例
     *
     * @param config MQ配置
     * @return 消息生产者
     */
    ProducerBean createProducer(BaseConfig config);

    /**
     * 根据配置创建一个消息消费者实例
     *
     * @param config          配置
     * @param messageListener 消息监听器
     * @return 消息消费者
     */
    ConsumerBean createConsumer(BaseConfig config, MessageListener messageListener);
}
